/*
 * @Author: ZhanXie
 * @Date: 2019-11-28 09:13:32
 * @LastEditors: ZhanXie
 * @LastEditTime: 2019-12-03 17:31:04
 * @Description: mysql 底层封装
 * @FilePath: /node-demo/blog-origin/src/db/mysql.js
 */
const mysql = require('mysql')
const { MY_SQLCONF } = require('../conf/db')

// 创建连接对象
const con = mysql.createConnection(MY_SQLCONF)

// 开始连接
con.connect()

// 统一执行 sql

function exec(sql) {
  const promise = new Promise((resolve, reject) => {
    con.query(sql, (err, result) => {
      if(err) {
        reject(err)
        return
      }
      resolve(result)
    })
  })
  return promise
}

// 连接完不断开 让他一直连着就可以了
// con.end()

module.exports = {
  exec,
  escape: mysql.escape // 把特殊字符转译, 防止 sql 注入 
}